package com.heima.admin.listener;

import com.heima.admin.service.UserAuthService;
import com.heima.model.comment.pojos.ApContent;
import lombok.RequiredArgsConstructor;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestBody;

@Service
@RequiredArgsConstructor
public class ContentListener {

        private final UserAuthService userAuthService;

        @KafkaListener(topics = ApContent.COMMENT_TOPIC)
        public void listen(@RequestBody ApContent apContent) {
//                      userAuthService.addAuth(apContent);
        }

}
